🌎 rns.kin.earth git 🌍

Tff7b72from T7ee787.T7ee787Interface Tff7b72import Te6edf3Interface

Tff7b72import T7ee787socketserver

Tff7b72import T7ee787threading

Tff7b72import T7ee787socket

Tff7b72import T7ee787time

Tff7b72import T7ee787sys

Tff7b72import T7ee787os

Tff7b72import T7ee787RNS

Tff7b72class T56d364HDLCTb4b4b4(Tb4b4b4)Tb4b4b4:

Te6edf3FLAG Tff7b72= T79c0ff0x7E

Te6edf3ESC Tff7b72= T79c0ff0x7D

Te6edf3ESC_MASK Tff7b72= T79c0ff0x20

Tf0883e@staticmethod

Tff7b72def Td2a8ffescapeTb4b4b4(Te6edf3dataTb4b4b4)Tb4b4b4:

Te6edf3data Tff7b72= Te6edf3dataTff7b72.Td2a8ffreplaceTb4b4b4(Tffa657bytesTb4b4b4(Tb4b4b4[Te6edf3HDLCTff7b72.Td2a8ffESCTb4b4b4]Tb4b4b4)Tb4b4b4, Tffa657bytesTb4b4b4(Tb4b4b4[Te6edf3HDLCTff7b72.Td2a8ffESCTb4b4b4, Te6edf3HDLCTff7b72.Td2a8ffESCTff7b72^Te6edf3HDLCTff7b72.Td2a8ffESC_MASKTb4b4b4]Tb4b4b4)Tb4b4b4)

Te6edf3data Tff7b72= Te6edf3dataTff7b72.Td2a8ffreplaceTb4b4b4(Tffa657bytesTb4b4b4(Tb4b4b4[Te6edf3HDLCTff7b72.Td2a8ffFLAGTb4b4b4]Tb4b4b4)Tb4b4b4, Tffa657bytesTb4b4b4(Tb4b4b4[Te6edf3HDLCTff7b72.Td2a8ffESCTb4b4b4, Te6edf3HDLCTff7b72.Td2a8ffFLAGTff7b72^Te6edf3HDLCTff7b72.Td2a8ffESC_MASKTb4b4b4]Tb4b4b4)Tb4b4b4)

Tff7b72return Te6edf3data

Tff7b72class T56d364ThreadingTCPServerTb4b4b4(Te6edf3socketserverTff7b72.Td2a8ffThreadingMixInTb4b4b4, Te6edf3socketserverTff7b72.Td2a8ffTCPServerTb4b4b4)Tb4b4b4:

Tff7b72pass

Tff7b72class T56d364TCPClientInterfaceTb4b4b4(Te6edf3InterfaceTb4b4b4)Tb4b4b4:

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3ownerTb4b4b4, Te6edf3nameTb4b4b4, Te6edf3target_ipTff7b72=Tff7b72NoneTb4b4b4, Te6edf3target_portTff7b72=Tff7b72NoneTb4b4b4, Te6edf3connected_socketTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffIN Tff7b72= Tff7b72True

Tff7b72selfTff7b72.Td2a8ffOUT Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffsocket Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffparent_interface Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffname Tff7b72= Te6edf3name

Tff7b72if Te6edf3connected_socket Tff7b72!= Tff7b72NoneTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffreceives Tff7b72= Tff7b72True

Tff7b72selfTff7b72.Td2a8fftarget_ip Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8fftarget_port Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffsocket Tff7b72= Te6edf3connected_socket

Tff7b72elif Te6edf3target_ip Tff7b72!= Tff7b72None Tff7b72and Te6edf3target_port Tff7b72!= Tff7b72NoneTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffreceives Tff7b72= Tff7b72True

Tff7b72selfTff7b72.Td2a8fftarget_ip Tff7b72= Te6edf3target_ip

Tff7b72selfTff7b72.Td2a8fftarget_port Tff7b72= Te6edf3target_port

Tff7b72selfTff7b72.Td2a8ffsocket Tff7b72= Te6edf3socketTff7b72.Td2a8ffsocketTb4b4b4(Te6edf3socketTff7b72.Td2a8ffAF_INETTb4b4b4, Te6edf3socketTff7b72.Td2a8ffSOCK_STREAMTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffsocketTff7b72.Td2a8ffconnectTb4b4b4(Tb4b4b4(Tff7b72selfTff7b72.Td2a8fftarget_ipTb4b4b4, Tff7b72selfTff7b72.Td2a8fftarget_portTb4b4b4)Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffowner Tff7b72= Te6edf3owner

Tff7b72selfTff7b72.Td2a8ffonline Tff7b72= Tff7b72True

Tff7b72selfTff7b72.Td2a8ffwriting Tff7b72= Tff7b72False

Tff7b72if Te6edf3connected_socket Tff7b72== Tff7b72NoneTb4b4b4:

Te6edf3thread Tff7b72= Te6edf3threadingTff7b72.Td2a8ffThreadTb4b4b4(Te6edf3targetTff7b72=Tff7b72selfTff7b72.Td2a8ffread_loopTb4b4b4)

Te6edf3threadTff7b72.Td2a8ffsetDaemonTb4b4b4(Tff7b72TrueTb4b4b4)

Te6edf3threadTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffprocessIncomingTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3dataTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffownerTff7b72.Td2a8ffinboundTb4b4b4(Te6edf3dataTb4b4b4, Tff7b72selfTb4b4b4)

Tff7b72def Td2a8ffprocessOutgoingTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3dataTb4b4b4)Tb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffonlineTb4b4b4:

Tff7b72while Tff7b72selfTff7b72.Td2a8ffwritingTb4b4b4:

Te6edf3timeTff7b72.Td2a8ffsleepTb4b4b4(T79c0ff0.01Tb4b4b4)

Tff7b72tryTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffwriting Tff7b72= Tff7b72True

Te6edf3data Tff7b72= Tffa657bytesTb4b4b4(Tb4b4b4[Te6edf3HDLCTff7b72.Td2a8ffFLAGTb4b4b4]Tb4b4b4)Tff7b72+Te6edf3HDLCTff7b72.Td2a8ffescapeTb4b4b4(Te6edf3dataTb4b4b4)Tff7b72+Tffa657bytesTb4b4b4(Tb4b4b4[Te6edf3HDLCTff7b72.Td2a8ffFLAGTb4b4b4]Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffsocketTff7b72.Td2a8ffsendallTb4b4b4(Te6edf3dataTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffwriting Tff7b72= Tff7b72False

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffException occurred while transmitting via Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Tff7b72selfTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff, tearing down interfaceTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffThe contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffteardownTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffread_loopTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72tryTb4b4b4:

Te6edf3in_frame Tff7b72= Tff7b72False

Te6edf3escape Tff7b72= Tff7b72False

Te6edf3data_buffer Tff7b72= Ta5d6ffbTa5d6ff"Ta5d6ff"

Tff7b72while Tff7b72TrueTb4b4b4:

Te6edf3data_in Tff7b72= Tff7b72selfTff7b72.Td2a8ffsocketTff7b72.Td2a8ffrecvTb4b4b4(T79c0ff4096Tb4b4b4)

Tff7b72if Tffa657lenTb4b4b4(Te6edf3data_inTb4b4b4) Tff7b72> T79c0ff0Tb4b4b4:

Te6edf3pointer Tff7b72= T79c0ff0

Tff7b72while Te6edf3pointer Tff7b72< Tffa657lenTb4b4b4(Te6edf3data_inTb4b4b4)Tb4b4b4:

Te6edf3byte Tff7b72= Te6edf3data_inTb4b4b4[Te6edf3pointerTb4b4b4]

Te6edf3pointer Tff7b72+Tff7b72= T79c0ff1

Tff7b72if Tb4b4b4(Te6edf3in_frame Tff7b72and Te6edf3byte Tff7b72== Te6edf3HDLCTff7b72.Td2a8ffFLAGTb4b4b4)Tb4b4b4:

Te6edf3in_frame Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffprocessIncomingTb4b4b4(Te6edf3data_bufferTb4b4b4)

Tff7b72elif Tb4b4b4(Te6edf3byte Tff7b72== Te6edf3HDLCTff7b72.Td2a8ffFLAGTb4b4b4)Tb4b4b4:

Te6edf3in_frame Tff7b72= Tff7b72True

Te6edf3data_buffer Tff7b72= Ta5d6ffbTa5d6ff"Ta5d6ff"

Tff7b72elif Tb4b4b4(Te6edf3in_frame Tff7b72and Tffa657lenTb4b4b4(Te6edf3data_bufferTb4b4b4) Tff7b72< Te6edf3RNSTff7b72.Td2a8ffReticulumTff7b72.Td2a8ffMTUTb4b4b4)Tb4b4b4:

Tff7b72if Tb4b4b4(Te6edf3byte Tff7b72== Te6edf3HDLCTff7b72.Td2a8ffESCTb4b4b4)Tb4b4b4:

Te6edf3escape Tff7b72= Tff7b72True

Tff7b72elseTb4b4b4:

Tff7b72if Tb4b4b4(Te6edf3escapeTb4b4b4)Tb4b4b4:

Tff7b72if Tb4b4b4(Te6edf3byte Tff7b72== Te6edf3HDLCTff7b72.Td2a8ffFLAG Tff7b72^ Te6edf3HDLCTff7b72.Td2a8ffESC_MASKTb4b4b4)Tb4b4b4:

Te6edf3byte Tff7b72= Te6edf3HDLCTff7b72.Td2a8ffFLAG

Tff7b72if Tb4b4b4(Te6edf3byte Tff7b72== Te6edf3HDLCTff7b72.Td2a8ffESC Tff7b72^ Te6edf3HDLCTff7b72.Td2a8ffESC_MASKTb4b4b4)Tb4b4b4:

Te6edf3byte Tff7b72= Te6edf3HDLCTff7b72.Td2a8ffESC

Te6edf3escape Tff7b72= Tff7b72False

Te6edf3data_buffer Tff7b72= Te6edf3data_bufferTff7b72+Tffa657bytesTb4b4b4(Tb4b4b4[Te6edf3byteTb4b4b4]Tb4b4b4)

Tff7b72elseTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffTCP socket for Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Tff7b72selfTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff was closed, tearing down interfaceTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_VERBOSETb4b4b4)

Tff7b72selfTff7b72.Td2a8ffteardownTb4b4b4(Tb4b4b4)

Tff7b72break

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffonline Tff7b72= Tff7b72False

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffAn interface error occurred, the contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffTearing down Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffteardownTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffteardownTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffonline Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffOUT Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffIN Tff7b72= Tff7b72False

Tff7b72if Tff7b72self Tff7b72in Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffinterfacesTb4b4b4:

Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffinterfacesTff7b72.Td2a8ffremoveTb4b4b4(Tff7b72selfTb4b4b4)

Tff7b72def Tff7b72__str__Tb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffTCPInterface[Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Tff7b72selfTff7b72.Td2a8ffnameTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff/Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Tff7b72selfTff7b72.Td2a8fftarget_ipTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff:Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Tff7b72selfTff7b72.Td2a8fftarget_portTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff]Ta5d6ff"

Tff7b72class T56d364TCPServerInterfaceTb4b4b4(Te6edf3InterfaceTb4b4b4)Tb4b4b4:

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3ownerTb4b4b4, Te6edf3nameTb4b4b4, Te6edf3bindipTff7b72=Tff7b72NoneTb4b4b4, Te6edf3bindportTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffIN Tff7b72= Tff7b72True

Tff7b72selfTff7b72.Td2a8ffOUT Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffname Tff7b72= Te6edf3name

Tff7b72if Tb4b4b4(Te6edf3bindip Tff7b72!= Tff7b72None Tff7b72and Te6edf3bindport Tff7b72!= Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffreceives Tff7b72= Tff7b72True

Tff7b72selfTff7b72.Td2a8ffbind_ip Tff7b72= Te6edf3bindip

Tff7b72selfTff7b72.Td2a8ffbind_port Tff7b72= Te6edf3bindport

Tff7b72def Td2a8ffhandlerFactoryTb4b4b4(Te6edf3callbackTb4b4b4)Tb4b4b4:

Tff7b72def Td2a8ffcreateHandlerTb4b4b4(Tff7b72*Te6edf3argsTb4b4b4, Tff7b72*Tff7b72*Te6edf3keysTb4b4b4)Tb4b4b4:

Tff7b72return Te6edf3TCPInterfaceHandlerTb4b4b4(Te6edf3callbackTb4b4b4, Tff7b72*Te6edf3argsTb4b4b4, Tff7b72*Tff7b72*Te6edf3keysTb4b4b4)

Tff7b72return Te6edf3createHandler

Tff7b72selfTff7b72.Td2a8ffowner Tff7b72= Te6edf3owner

Te6edf3address Tff7b72= Tb4b4b4(Tff7b72selfTff7b72.Td2a8ffbind_ipTb4b4b4, Tff7b72selfTff7b72.Td2a8ffbind_portTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffserver Tff7b72= Te6edf3ThreadingTCPServerTb4b4b4(Te6edf3addressTb4b4b4, Te6edf3handlerFactoryTb4b4b4(Tff7b72selfTff7b72.Td2a8ffincoming_connectionTb4b4b4)Tb4b4b4)

Te6edf3thread Tff7b72= Te6edf3threadingTff7b72.Td2a8ffThreadTb4b4b4(Te6edf3targetTff7b72=Tff7b72selfTff7b72.Td2a8ffserverTff7b72.Td2a8ffserve_foreverTb4b4b4)

Te6edf3threadTff7b72.Td2a8ffsetDaemonTb4b4b4(Tff7b72TrueTb4b4b4)

Te6edf3threadTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffincoming_connectionTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3handlerTb4b4b4)Tb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffAccepting incoming TCP connectionTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_VERBOSETb4b4b4)

Te6edf3interface_name Tff7b72= Ta5d6ff"Ta5d6ffClient on Ta5d6ff"Tff7b72+Tff7b72selfTff7b72.Td2a8ffname

Te6edf3spawned_interface Tff7b72= Te6edf3TCPClientInterfaceTb4b4b4(Tff7b72selfTff7b72.Td2a8ffownerTb4b4b4, Te6edf3interface_nameTb4b4b4, Te6edf3target_ipTff7b72=Tff7b72NoneTb4b4b4, Te6edf3target_portTff7b72=Tff7b72NoneTb4b4b4, Te6edf3connected_socketTff7b72=Te6edf3handlerTff7b72.Td2a8ffrequestTb4b4b4)

Te6edf3spawned_interfaceTff7b72.Td2a8ffOUT Tff7b72= Tff7b72selfTff7b72.Td2a8ffOUT

Te6edf3spawned_interfaceTff7b72.Td2a8ffIN Tff7b72= Tff7b72selfTff7b72.Td2a8ffIN

Te6edf3spawned_interfaceTff7b72.Td2a8fftarget_ip Tff7b72= Te6edf3handlerTff7b72.Td2a8ffclient_addressTb4b4b4[T79c0ff0Tb4b4b4]

Te6edf3spawned_interfaceTff7b72.Td2a8fftarget_port Tff7b72= Tffa657strTb4b4b4(Te6edf3handlerTff7b72.Td2a8ffclient_addressTb4b4b4[T79c0ff1Tb4b4b4]Tb4b4b4)

Te6edf3spawned_interfaceTff7b72.Td2a8ffparent_interface Tff7b72= Tff7b72self

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffSpawned new TCPClient Interface: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3spawned_interfaceTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_VERBOSETb4b4b4)

Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffinterfacesTff7b72.Td2a8ffappendTb4b4b4(Te6edf3spawned_interfaceTb4b4b4)

Te6edf3spawned_interfaceTff7b72.Td2a8ffread_loopTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffprocessOutgoingTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3dataTb4b4b4)Tb4b4b4:

Tff7b72pass

Tff7b72def Tff7b72__str__Tb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffTCPServerInterface[Ta5d6ff"Tff7b72+Tff7b72selfTff7b72.Td2a8ffnameTff7b72+Ta5d6ff"Ta5d6ff/Ta5d6ff"Tff7b72+Tff7b72selfTff7b72.Td2a8ffbind_ipTff7b72+Ta5d6ff"Ta5d6ff:Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Tff7b72selfTff7b72.Td2a8ffbind_portTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff]Ta5d6ff"

Tff7b72class T56d364TCPInterfaceHandlerTb4b4b4(Te6edf3socketserverTff7b72.Td2a8ffBaseRequestHandlerTb4b4b4)Tb4b4b4:

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3callbackTb4b4b4, Tff7b72*Te6edf3argsTb4b4b4, Tff7b72*Tff7b72*Te6edf3keysTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffcallback Tff7b72= Te6edf3callback

Te6edf3socketserverTff7b72.Td2a8ffBaseRequestHandlerTff7b72.Td2a8ff__init__Tb4b4b4(Tff7b72selfTb4b4b4, Tff7b72*Te6edf3argsTb4b4b4, Tff7b72*Tff7b72*Te6edf3keysTb4b4b4)

Tff7b72def Td2a8ffhandleTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffcallbackTb4b4b4(Te6edf3handlerTff7b72=Tff7b72selfTb4b4b4)